

class Celery(object):

    def broker(self, func):
        # 任务队列
        self.borker_list = []
        self.borker_list.append(func)

    def worker(self, func):
        # 任务执行者
        if func in self.borker_list:
            func()
